package com;

/**
 * @author Tindy
 * @date 2022/5/15
 * @describe
 */
public class T {
    public static void main(String[] args) {
        String logInfo="CREATE TABLE sys_department1 (\n" +
                "    id INT,\n" +
                "    parent_id INT,\n" +
                "    parent_ids STRING,\n" +
                "    name VARCHAR(64),\n" +
                "    create_time TIMESTAMP,\n" +
                "    update_time TIMESTAMP,\n" +
                "PRIMARY KEY (id) NOT ENFORCED\n" +
                ")WITH (\n" +
                "    'connector' = 'jdbc',\n" +
                "    'url' = 'jdbc:mysql://10.168.1.140:3306/test?characterEncoding=UTF-8',\n" +
                "    'username' = 'root',\n" +
                "    'password' = '1gjbay#wp6zK',\n" +
                "    'table-name' = 'sys_department'\n" +
                ");\n" +
                "CREATE TABLE sys_department2 (\n" +
                "    id INT,\n" +
                "    parent_id INT,\n" +
                "    parent_ids STRING,\n" +
                "    name STRING,\n" +
                "    create_time TIMESTAMP,\n" +
                "    update_time TIMESTAMP\n" +
                "\n" +
                ") WITH (\n" +
                "    'connector' = 'kafka',\n" +
                "    'topic' = 'kafka_pub_db1.t1',\n" +
                "    'properties.bootstrap.servers' = 'cdh3:9092',\n" +
                "    'format' = 'json',\n" +
                "    'properties.keytab.url' = 'http://10.168.1.140/group1/M00/00/00/CqgBjGJ3WQaAS5_vAAACGgtPxl4.keytab',\n" +
                "    'properties.krb5conf.url' = 'http://10.168.1.140/group1/M00/00/00/CqgBjGJ3WR2AFCmSAAACWjzKq9k40.conf',\n" +
                "    'properties.principal' = 'kafka/cdh3',\n" +
                "    'properties.group.id' = 'testGroup',\n" +
                "    'scan.startup.mode'='earliest-offset'\n" +
                "\n" +
                ");";
        logInfo=logInfo.replaceAll("\n    'username' = '.*',\n","\n    'username' = '******',\n");
        logInfo=logInfo.replaceAll("\n    'password' = '.*',\n","\n    'username' = '******',\n");
        logInfo=logInfo.replaceAll("\n    'properties.keytab.url' = '.*',\n","\n    'properties.keytab.url' = '******',\n");
        logInfo=logInfo.replaceAll("\n    'properties.krb5conf.url' = '.*',\n","\n    'pasproperties.krb5conf.urlsword' = '******',\n");
        logInfo=logInfo.replaceAll("\n    'properties.principal' = '.*',\n","\n    'properties.principal' = '******',\n");
        System.out.print(logInfo);

    }
}
